package org.lzfto.flink.demo.business.flinkTest.entity;

import java.io.Serializable;

/**
*
*@author lzfto
*@创建时间 2025年7月10日 09:47:47
*/
public record ClickEventSourceConfig(
		int testElapseSecs, //生成测试数据的整个过程的时间长度
		int winLen, //处理窗口长度(秒)
		int winLateness,  //处理窗口允许的延迟时间(秒)
		int extraLateness //额外的延迟时间(秒）
		) implements Serializable 
{
   public int  getMaxLateness() {
	   return winLen+winLateness+extraLateness;
   }
}
